package com.central.common.entity;

import com.central.common.model.DatasourceInfo;
import com.central.common.model.TableInfo;
import lombok.Getter;
import lombok.Setter;

import java.io.Serializable;
import java.util.List;
import java.util.Map;

/**
 * @author Tindy
 * @date 2022/4/6
 * @describe
 */
@Getter
@Setter
public class FlinkTable implements Serializable {
    private Long datasourceId;
    private DatasourceInfo datasource;
    private String dbName;
    private String tableName;
    private List<String> primaryKeys;
    private TableInfo tableInfo;
    private Map<String,String> withParams;
    private Boolean isCdc;
}
